package com.jeegod.stream.in1.service;

// @EnableBinding(SendToBinder.class)
public class SendToService {
    // @StreamListener("input")
    // @SendTo("output")
    public Object receiveFromInput(Object payload){
        System.out.println("中转消息。。"+payload);
        return "xxxxx";
    }
}
